package com.heima.leadnews.kafakstream.stream;

import org.apache.kafka.streams.kstream.KStream;
import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;

/**
 * 定义Topic主题和Sink主题
 */
public interface KafkaStreamsProcessor {
      @Input("ArticSource")
    KStream<String,String> input();

    @Output("ArticSink")
    KStream<String,String> output();

}
